package com.bunnymaicai.boot.kafka.autoconfigure;

import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;

/**
 *
 * @author youshang
 * @date 2021/02/25 17:34
 **/
@Data
@ConfigurationProperties(prefix = "spring.kafka")
public class KafkaConfiguration {

    private String bootstrapServers;
    private KafkaConsumer consumer = new KafkaConsumer();
    private KafkaProducer producer = new KafkaProducer();

    @Data
    class KafkaConsumer{
        private String keyDeserializer;
        private String valueDeserializer;
        private String  autoOffsetReset;
    }
    @Data
    class KafkaProducer{
        private String keySerializer;
        private String valueSerializer;
    }



}
